package com.ywu.mq.sdk.config;

import lombok.Data;
import lombok.ToString;

/**
 *
 *
 * @author Administrator
 * @date 2025/11/01
 */
@ToString
@Data
public class YwuKafkaSdkProduceConfig {
    private String bootstrapService;

    private String keySerializer = "org.apache.kafka.common.serialization.StringSerializer";

    private String valueSerializer = "org.apache.kafka.common.serialization.StringSerializer";

    private String topicName;

    private String appId;

    private String appKey;

    private String topicAppId;

    private String key;

    private Boolean enablePermissionCheckBegin = true;

    // 连接时间
    private int connectTimeout = 10;

    // 读取超时时间
    private int readTimeout = 10;

    // 写入超时时间
    private int writeTimeout = 10;

    // MQ平台地址信息
    private String mqPlatformHost;
}
